package com.xxx.listener;

/**
 * MQ消费监听器
 */
public class MqListener {
	// 具体执行业务的方法
	public void listen(String msg) {
		System.out.println("mq消费者开始处理消息： " + msg + "");
	}
}
